package com.example.gank.api;

import com.example.gank.bean.Result;

import rx.functions.Func1;

public class ResponseFunc<T> implements Func1<Result<T>, T> {

    private static final String RESP_OK = "ok";

    //此处逻辑根据约定报文进行修改，实现逻辑即可
    @Override
    public T call(Result<T> httpResult) {
        if (httpResult.isError()) {
            // 在此处抛出异常，subscribe的onError方法中会收到异常。
            // 抛出的异常不能是会使系统崩溃的检查异常，如OOM
            throw new IllegalStateException("请求失败，请稍后重试");
        }
        return httpResult.getResults();
    }
}